062bd5bc67d1b8362b3c5ebc696e08f525f05810,spring-social-twitter/src/main/java/org/springframework/social/twitter/api/impl/StreamDispatcher.java,StreamDispatcher,handleWarning,#String#,109

Before Change


	private void handleWarning(String line) throws IOException {
		final StreamWarningEvent warningEvent = objectMapper.readValue(line, StreamWarningEvent.class);
		for (final StreamListener listener : listeners) {
			new Thread(new Runnable() {
				public void run() {
					listener.onWarning(warningEvent);
				}
			}).start();
		}
	}
	

After Change


	private void handleWarning(String line) throws IOException {
		final StreamWarningEvent warningEvent = objectMapper.readValue(line, StreamWarningEvent.class);
		for (final StreamListener listener : listeners) {
			Future<?> result = pool.submit((new Runnable() {
				public void run() {
					listener.onWarning(warningEvent);
				}
			}));
		}
	}